package com.tx.server.message;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface StreamRespond {

    String RESPONDINPUT = "respond-input";
    String RESPONDOUTPUT = "respond-output";

    @Input(RESPONDINPUT)
    SubscribableChannel input();  // 订阅通道

    @Output(RESPONDOUTPUT)
    MessageChannel output();  // 消息通道
}
